[AFF-BACKEND-001] Создать Метод FilterInboundEvents()

Разработка фильтрующего воркера и регистратора интеракций

NoteКраткая карточка задачи

• Репозиторий / Компонент: helper-service (Домен Recommendation Domain).
• Контракт метода: Асинхронный Kafka-consumer топиков bpds.mdm.out.product.templated и bpds.inventory.out.meal_item.create.
• Ссылка на Метод: Спецификация метода
• Статус: Готово к реализации

---

• Инструкция по шагам:
  1. Настроить подписку воркера на два канонических топика.
  2. Бизнес-правило фильтрации: При получении сообщений из топика готовки bpds.inventory.out.meal_item.create немедленно игнорировать и сбрасывать их (Ack), так как внутреннее приготовление еды не влияет на покупательское аффинити.
  3. На Шаге 1: При получении очищенного JSON-пакета новых трат из топика bpds.mdm.out.product.templated, распарсить массив купленных позиций, извлечь user_id и x_request_id (trace_id).
  4. На Шаге 2: Выполнить синхронный gRPC-вызов к смежному сервису affinity-service, вызвав метод RegisterInteraction(RegisterRequest) и передав структуру user_id и плоский список идентификаторов продуктов items_list.